package com.hsurosy.hsuchain.nft.stream.config;

import com.hsurosy.hsuchain.nft.stream.producer.StreamProducer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 流配置类
 *
 * @Author Hsu琛君珩
 * @Date 2024-10-05 4:46
 * @Description
 * @Version: v1.0.0
 */
@Configuration
public class StreamConfiguration {

    /**
     * 配置流生产者。
     * <p>
     * 该方法用于创建和初始化一个StreamProducer实例，管理消息的生产。
     *
     * @return StreamProducer 实例，用于消息生产
     */
    @Bean
    public StreamProducer streamProducer() {
        // 创建并返回StreamProducer对象
        StreamProducer streamProducer = new StreamProducer();
        return streamProducer;
    }
}
